package com.nuanshui.heatedloan.middleware.rabbitmq;

import org.springframework.amqp.core.Message;

import com.rabbitmq.client.Channel;

/**
 * 消息队列处理类的接口定义
 * @param 
 * @author guohao
 * @date 2017年2月10日 上午10:42:07
 * @since $
 */
public interface RabbitmqMessageHandler {
	
	/**
	 * 消息处理的方法
	 * @param @param message 消息
	 * @param @param channel 玉消息队列连接的channel
	 * @param @throws Exception
	 * @author guohao
	 * @date 2017年2月10日 上午10:43:22
	 * @since $
	 */
	void onMessage(Message message, Channel channel) throws Exception;

}
